input {
    file {
        type => "worker_log"
        path => ["/var/log/worker/*.log"]
        start_position => "beginning"
        exclude => "*.gz"
    }
}

output {
    if [type] == "worker_log" {
        elasticsearch {
            hosts => ["{{ monitor_ip }}:9200"]
            index => "worker-log"
        }
    }
}
